package com.jielihaofeng.springboot.kafka.test;

import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author Johnnie Wind
 * @description kafka配置类，初始化topic
 * @date 2021/3/3 14:31
 */
@Configuration
public class KafkaInitialConfiguration {
    // 创建一个名为testtopic的Topic并设置分区数为1，分区副本数为1
//    @Bean
//    public NewTopic initialTopic() {
//        return new NewTopic("topic_wzy", 1, (short) 1);
//    }
//
//    // 如果要修改分区数，只需修改配置值重启项目即可
//    // 修改分区数并不会导致数据的丢失，但是分区数只能增大不能减小
//    @Bean
//    public NewTopic updateTopic() {
//        return new NewTopic("topic_wzy", 1, (short) 1);
//    }
}
